otel: subchannel metrics #12202
otel: subchannel metrics #12202
Conversation
AgraVator
force-pushed
the
otel-subchannel-metrics
branch
from
eabbf58 to
9595507
Compare
| subchannelMetrics.recordConnectionAttemptFailed(buildLabelSet( | ||
| getAttributeOrDefault( | ||
| addressIndex.getCurrentEagAttributes(), NameResolver.ATTR_BACKEND_SERVICE), | ||
| getAttributeOrDefault( | ||
| addressIndex.getCurrentEagAttributes(), LoadBalancer.ATTR_LOCALITY_NAME), | ||
| null, null | ||
| )); |
There was a problem hiding this comment.
Should this be triggered from here or before addressIndex.increment() at 658 ?
AgraVator
force-pushed
the
otel-subchannel-metrics
branch
from
9595507 to
c713561
Compare
| @@ -415,7 +415,7 @@ void exitIdleMode() { | |||
| LbHelperImpl lbHelper = new LbHelperImpl(); | |||
| lbHelper.lb = loadBalancerFactory.newLoadBalancer(lbHelper); | |||
| // Delay setting lbHelper until fully initialized, since loadBalancerFactory is user code and | |||
| // may throw. We don't want to confuse our state, even if we will enter panic mode. | |||
| // may throw. We don't want to confuse our state, even if we enter panic mode. | |||
There was a problem hiding this comment.
I think the comment is more accurate as it is. After entering panic mode there is nothing much we can do about state, the comment implies delaying entering that panic mode and maintaining a sane state for the channel for as long as possible before bringing in potential user code.
| addressIndex.getCurrentEagAttributes(), NameResolver.ATTR_BACKEND_SERVICE), | ||
| getAttributeOrDefault( | ||
| addressIndex.getCurrentEagAttributes(), LoadBalancer.ATTR_LOCALITY_NAME), | ||
| "Peer Pressure", |
There was a problem hiding this comment.
This is not in the gRFC? Instead there is a "List of allowed values for grpc.disconnect_error".
There was a problem hiding this comment.
For Phase 1 we won't be plumbing disconnect_error, will raise another PR with this as the base branch for the same
core/src/main/java/io/grpc/internal/PickFirstLeafLoadBalancer.java
Outdated
Show resolved
Hide resolved
core/src/main/java/io/grpc/internal/DelayedClientTransport.java
Outdated
Show resolved
Hide resolved
| @@ -593,6 +602,15 @@ public void run() { | |||
| pendingTransport = null; | |||
| connectedAddressAttributes = addressIndex.getCurrentEagAttributes(); | |||
| gotoNonErrorState(READY); | |||
| subchannelMetrics.recordConnectionAttemptSucceeded(buildLabelSet( | |||
There was a problem hiding this comment.
Label for target? Also for disconnections and connection attempt failures below.
There was a problem hiding this comment.
buildLabelSet() gets it from the class var
| * @param optionalLabelValues the optional label values for the metric. | ||
| */ | ||
| @Override | ||
| public void addLongUpDownCounter(LongUpDownCounterMetricInstrument metricInstrument, long value, |
There was a problem hiding this comment.
These are just wrappers on the underlying OTel API for UpDownCounter...
| @@ -117,6 +119,22 @@ public void addLongCounter(LongCounterMetricInstrument metricInstrument, long va | |||
| counter.add(value, attributes); | |||
| } | |||
|
|
|||
| @Override | |||
| public void addLongUpDownCounter(LongUpDownCounterMetricInstrument metricInstrument, long value, | |||
| * @return the newly created LongUpDownCounterMetricInstrument | ||
| * @throws IllegalStateException if a metric with the same name already exists | ||
| */ | ||
| public LongUpDownCounterMetricInstrument registerLongUpDownCounter(String name, |
Implements A94